package test;

import java.io.*;

import java.net.*;

import java.util.*;

 

public class MulticastServerThread extends Thread {

 

    private long FIVE_SECONDS = 5000;

 protected DatagramSocket socket = null;

    protected BufferedReader in = null;

    protected boolean moreQuotes = true;

    public MulticastServerThread() throws IOException {

        super("MulticastServerThread");

    }

 

    public void run() {

        while (true) {

            try {

                byte[] buf = new byte[256];

 

                // construct quote

                

                String    dString = "asd";

                buf = dString.getBytes();

 

                // send it

                InetAddress group = InetAddress.getByName("230.0.0.1");

                DatagramPacket packet = new DatagramPacket(buf, buf.length,

                    group, 4446);

                socket.send(packet);

 

                // sleep for a while

                try {

                    sleep((long)(Math.random() * FIVE_SECONDS));

                } catch (InterruptedException e) { }

            } catch (IOException e) {

                e.printStackTrace();

                moreQuotes = false;

            }

        }

        //socket.close();

    }

}